<?php
namespace app\api\controller;
use app\ApibaseController;//api 基类
use think\facade\Queue;
class Xcx extends ApibaseController
{	
		// 生产者，添加消息队列
	    public function addQueue()
	    {	

	        // 参数
	        $data = [
	            'id' => rand(0, 99),
	            'userName' => 'xx',
	            'logic'=>'CatLogic',
	            'method'=>'test'
	        ];

	        $queueName = 'testQueue';

	        $isPushed = Queue::push('app\jobs\sendJob', $data, $queueName);
			// PHP5.5以下的可以直接写命名空间
	        // $isPushed = Queue::push('app\common\queue\TestQueue', $data, $queueName);
	        
	        if ($isPushed !== false) {
	            // 成功之后的业务
	            echo 'yes';
	        } else {
	            // 失败之后的业务
	            echo 'no';
	        }
	    }
 
}